//package com.xiao.websocket;
//
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.context.annotation.Configuration;
//import org.springframework.http.server.ServerHttpRequest;
//import org.springframework.http.server.ServerHttpResponse;
//import org.springframework.web.socket.WebSocketHandler;
//import org.springframework.web.socket.config.annotation.EnableWebSocket;
//import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
//import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;
//import org.springframework.web.socket.server.HandshakeInterceptor;
//import java.util.Map;
//
///**
// * @Describe: websocket服务（spring实现）
// * @Author: yangchengxiao
// * @Date: 2021/4/14 16:03
// */
//@Slf4j
//@Configuration
//@EnableWebSocket
//public class WebSocketConfig implements WebSocketConfigurer {
//
//    @Override
//    public void registerWebSocketHandlers(WebSocketHandlerRegistry webSocketHandlerRegistry) {
//        webSocketHandlerRegistry.addHandler(new MyWebSocketHandler(), "/websocket/server") // 设置websocket处理器
//                .setAllowedOrigins("*")
//                .addInterceptors(new MyWebSocketInterceptor()); // 设置websocket拦截器
//    }
//
//
//    static class MyWebSocketInterceptor implements HandshakeInterceptor {
//        @Override
//        public boolean beforeHandshake(ServerHttpRequest serverHttpRequest, ServerHttpResponse serverHttpResponse, WebSocketHandler webSocketHandler, Map<String, Object> map) throws Exception {
//            log.info("websocket 前置拦截");
//            return true;
//        }
//
//        @Override
//        public void afterHandshake(ServerHttpRequest serverHttpRequest, ServerHttpResponse serverHttpResponse, WebSocketHandler webSocketHandler, Exception e) {
//            log.info("websocket 后置拦截");
//        }
//    }
//}
